package com.free.food.order.mq.receiver;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * 类功能描述：
 *
 * @author：刘富国
 * @createTime：2019-02-27 17:46
 */
public interface StreamClient {
    String INPUT = "myMessage";

//    @Input(value = StreamClient.INPUT)
//    SubscribableChannel input();


    @Output(value = StreamClient.INPUT)
    MessageChannel output();

}
